package com.example.parition;

import org.apache.flink.api.common.functions.Partitioner;

/**
 * Created with IntelliJ IDEA.
 * ClassName: MyPartitioner
 * Package: com.example.parition
 * Description:
 * User: fzykd
 *
 * @Author: LQH
 * Date: 2023-07-18
 * Time: 20:53
 */

public class MyPartitioner implements Partitioner<String> {
    @Override
    public int partition(String s, int i) {
        return Integer.parseInt(s) % i;
    }
}
